package com.qst.mapreduce.wordcount.diliuzhang.zuoye.dierjie;

import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Partitioner;


public class CustomPartitioner extends Partitioner<Text,App > {
    @Override
    public int getPartition(Text key, App value, int i) {
       if (key.toString().equals("微信")){
           return 0;
       }
       else {
           return 1;
       }

    }
}
